package com.ceam.orderservice;

import com.ceam.MessageInput;
import com.sun.tools.example.debug.tty.MessageOutput;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.integration.support.MessageBuilder;

@EnableBinding(MessageInput.class)
public class MyEventConsumer {

    @StreamListener(MessageInput.INPUT)
    public void handleMessage(String message) {
        // 处理消息
        System.out.println("Received message: " + message);
    }
}


